package cc.rboot.topic.core;

public interface IMessageConsumer<T> {

    IMessageTopic<T> topic();

    String name();

    boolean onMessage(T message) throws Exception;

}
